package chapter04

import org.apache.spark.sql.{DataFrame, SparkSession}

object SparkSessionApp {
  def main(args: Array[String]): Unit = {

    val spark: SparkSession = SparkSession.builder()
      .master("local")
      .appName("SparkSessionApp")
      .getOrCreate()

    import spark.implicits._

    val df: DataFrame = spark.read.text("file:///D:\\JAVApros\\spark_pk\\data\\input.txt")
    df.show()

    spark.stop()

  }

}
